import json
# 10.20.2.19
from rpc.aikafka.kafka_kit_json import Kafka_producer


def send():
    # producer = Kafka_producer(bootstrap_servers='10.20.5.3', kafkatopic='shanma',
    #                           is_json=True)
    producer = Kafka_producer(bootstrap_servers='10.20.2.19', kafkatopic='facedetect',
                              is_json=True)
    producer.send_df({'status':'ok'})
if __name__ == '__main__':
    send()